#include "commd.hpp"
using namespace std;

int main() {
    // 第0步：创建并打开命名管道文件
    int res = mkfifo(CHANNEL_NAME, 0666);
    if (res == -1) {
        cerr << "errno:" << errno << "errnostring:" << strerror(errno) << endl;
       return -1; 
    }
    cout << "打开管道文件成功" << endl;

    // 第1步：使用ftok生成一个唯一的key
    key_t key = get_key();

    // 第2步：使用shmget创建并获取共享内存
    int shmid = shmget(key, SIZE, IPC_CREAT | IPC_EXCL | 0666);
    if (shmid == -1) {
        cerr << "errno:" << errno << "errnostring:" << strerror(errno) << endl;
        return -1;
    }
    cout << "创建并获取共享内存成功, shmid==" << shmid << endl;

    // 第3步：使用shmat接口将当前进程挂接到共享内存上
    char* s = (char*)shmat(shmid, nullptr, 0);

    // 打开管道文件
    int fd = open(CHANNEL_NAME, O_RDONLY);
    if (fd < 0) {
        cerr << "errno:" << errno << "errnostring:" << strerror(errno) << endl;
        return -1;
    }
    cout << "打开管道文件成功" << endl;


    // 第4步：从共享内存中读(并处理同步问题)
    while (true) {
        int code = 1;
        int n = read(fd, &code, sizeof(code));
        if (n == sizeof(code)) {
            cout << "sharememory `s content:" << s << endl;
            sleep(1);
        } else if (n == 0) {
            break;
        }

    }


    // 第5步：使用shmdt将当前进程与共享内存去关联
    shmdt(s);

    // 第6步：使用shmctl将共享内存删除
    shmctl(shmid, IPC_RMID, nullptr);
    cout << "关闭共享内存成功" << endl;
    close(fd); // 关闭管道文件
    return 0;
}